kafka Avro消息反序列化器，可用于多个主题
我正在尝试使用以下代码以avro格式反序列化kafka消息：[https](https://github.com/ivangfr/springboot-kafka-debezium-ksql/blob/master/kafka-research-consumer/src/main/java/com/mycompany/kafkaresearchconsumer/kafka/ReviewsConsumerConfig.java)//github.com/ivangfr/springboot-kafka-deb...
2024-01-10如何为Kafka 2.2实现FlinkKafkaProducer序列化程序
我一直在努力更新从Kafka读取然后写入Kafka的Flink处理器（Flink 1.9版）。我们已经将此处理器编写为可以朝着Kafka0.10.2集群运行，现在我们已经部署了一个运行2.2版的新Kafka集群。因此，我着手更新处理器以使用最新的FlinkKafkaConsumer和FlinkKafkaProducer（由Flink文档建议）。但是我遇到了卡夫卡制片人的一些问...
2024-01-10Kafka 0.8.2.2-无法发布消息
我们已经编写了一个Java客户端，用于将消息发布到kafka。代码如下所示Properties props = new Properties();props.setProperty(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "202.xx.xx.xxx:9092");props.setProperty(ProducerConfig.METADATA_FETCH_TIMEOUT_CONFIG,Integer.toString(5 * 1000));props.put(P...
2024-01-10在kafka集群上启用ssl时，kafka连接无法启动
我正在评估kafka汇合平台4.0版。但是，当我在kafka集群上启用ssl时，kafka连接无法启动。在kafka集群上启用ssl时，kafka连接无法启动详细记录如下：[2017-12-18 04:38:55,747] ERROR Uncaught exception in herder work thread, exiting: (org.apache.kafka.connect.runtime.distributed.DistributedHerder:218) org.apache.kafka.c...
2024-01-10使用Spring Kafka反序列化来自同一Kafka主题的不同JSON有效负载
我正在尝试反序列化来自同一Kafka主题的不同JSON负载。在这里提出的其他问题使我第一次尝试，但是我无法使其运行。正如Gary提到的，有一些提示（JsonSerializer.ADD_TYPE_INFO_HEADERS），但是当我发送和接收这两个消息时，我都会遇到异常。org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method cou...
2024-01-10如何在kafka中创建自定义序列化程序？
序列化器很少，例如org.apache.kafka.common.serialization.StringSerializerorg.apache.kafka.common.serialization.StringSerializer我们如何创建自己的自定义序列化程序？回答：在这里，您有一个示例，将自己的序列化器/解串器用于Kafka消息值。对于Kafka消息密钥是同一回事。我们希望将MyMessage的序列化版本作为Kafka值发送...
2024-01-10kafka获取主题的分区计数
如何从代码中获取任何kafka主题的分区数。我研究了许多链接，但似乎没有一个起作用。提及一些：http://grokbase.com/t/kafka/users/148132gdzk/find-topic-partition-count-through-simpleclient-apihttp://grokbase.com/t/kafka/users/151cv3htga/get-replication-and-partition-count-of-a-topichttp://qnalist.com/que...
2024-01-10如何获取kafka主题分区的最后/结束偏移量？
我正在kafka使用Java编写使用者。我想保持消息的实时性，因此，如果有太多消息在等待使用，例如1000条或更多，我应该放弃未使用的消息，并从最后一个偏移量开始使用。对于此问题，我尝试比较主题的最后提交的偏移量和主题的结束偏移量（仅1个分区），如果这两个偏移量之间的差大于某个值，则...
2024-01-10在Kafka用户中重试用尽时如何设置确认
我有一个重试5次的Kafka使用者，并且我正在使用带有重试模板的SpringKafka。现在，如果所有重试都失败了，那么在这种情况下如何确认工作。另外，如果我将确认模式设置为手动，那么如何确认这些消息消费者@Bean("kafkaListenerContainerFactory")public ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerContain...
2024-01-10Kafka如何存储每个主题的偏移量？
在轮询Kafka时，我已经使用该subscribe()功能订阅了多个主题。现在，我想设置的偏离，我想从每个主题阅读，而无需每次重新订阅后seek()，并poll()从一个话题。seek()，是否可以迭代调用每个主题名称 达到结果？偏移量如何精确存储在Kafka中？我每个主题有一个分区，并且只有一个使用者可以读取所有主...
2024-01-10春云流Kafka粘结剂：“尝试从状态IN_TRANSACTION到状态IN_TRANSACTION的无效转换”
我正在尝试使用Spring云流+ Kafka绑定对Apache Kafka进行“恰好一个交付”概念的一些PoC。春云流Kafka粘结剂：“尝试从状态IN_TRANSACTION到状态IN_TRANSACTION的无效转换”我安装了Apache Kafka“kafka_2.11-1.0.0”，并在生产者中定义了“transactionIdPrefix”，我知道这是我在Spring Kafka中启用事务所需要做的唯一事情，但...
2024-01-10如何在Kafka中使用多个消费者？
我是一名学习Kafka的新学生，在了解多个消费者（到目前为止，文章，文档等对他们没有太大帮助）方面，我遇到了一些基本问题。我尝试做的一件事是编写我自己的高级Kafka生产者和消费者并同时运行它们，将100条简单消息发布到某个主题，然后让消费者检索它们。我已经成功地做到了这一点，但是...
2024-01-10Kafka-经纪人：小组协调员不可用
我有以下结构：zookeeper: 3.4.12kafka: kafka_2.11-1.1.0server1: zookeeper + kafkaserver2: zookeeper + kafkaserver3: zookeeper + kafka通过kafka-topics shell脚本创建了具有复制因子3和分区3的主题。./kafka-topics.sh --create --zookeeper localhost:2181 --topic test-flow --partitions 3 --re...
2024-01-10将自定义Java对象发送到Kafka主题
我有我的自定义Java对象，希望利用JVM的内置序列化将其发送到Kafka主题，但是序列化失败并出现以下错误org.apache.kafka.common.errors.SerializationException：无法将com.spring.kafka.Payload类的值转换为value.serializer中指定的org.apache.kafka.common.serialization.ByteArraySerializer类。public class Payload implements Seri...
2024-01-10Kafka“未在JAAS配置中指定登录模块”
与sasl使用控制台脚本保护的Kafka通信时出现问题。Kafka受保护sasl，监听器受保护SASL_PLAINTEXT，机制由PLAIN。我做了什么：我尝试使用kafka脚本之一列出一些数据：bin/kafka-consumer-groups.sh --bootstrap-server (address) --list但是我明白了WARN Bootstrap broker (address) disconnected (org.apache.kafka.clients.NetworkClient)命令失...
2024-01-10Kafka-使用高级使用者的延迟队列实施
想要使用高级消费者API实现延迟的消费者大意：按键生成消息（每个消息包含创建时间戳记），以确保每个分区按生成时间对消息进行排序。auto.commit.enable = false（将在每个消息处理之后显式提交）消费一条消息检查消息时间戳，并检查是否经过了足够的时间处理消息（此操作将永不失败）提交1...
2024-01-10如何通过Java在Kafka中创建主题
我想通过Java在Kafka（kafka_2.8.0-0.8.1.1）中创建一个主题。如果我在命令提示符下创建一个主题，并且如果我通过javaapi推送消息，它也可以正常工作。但是我想通过java api创建一个主题。经过长时间的搜索，我发现了以下代码，ZkClient zkClient = new ZkClient("localhost:2181", 10000, 10000);AdminUtils.createTopic(zkClient, myTo...
2024-01-10Kafka：使用Java更改特定主题的分区数
我是Kafka的新手，正在使用新的KafkaProducer和KafkaConsumer，版本：0.9.0.1在创建特定主题之后，java中是否有任何方法可以更改/更新特定主题的分区数。我没有使用Zookeeper创建主题。当发布请求到达时，我的KafkaProducer会自动创建主题。如果还不够，我还可以提供更多详细信息回答：是的，有可能。您必须...
2024-01-10使用java插入对pdf的评论
我想在现有pdf文件中使用java.i插入特定文本的粘滞便笺，必须搜索pdf中的所有特定单词并将其标记为注释。当我把鼠标放在评论上时，应该显示存储的单词。使用java插入对pdf的评论谁能帮助我在这个..回答：看一看iText。您可以将annotation添加到PDF。...
2024-01-10通过Java使用大图像压缩pdf
寻找一种将图像压缩为pdf格式并输出pdf进行存档的方法。我无法在创建图像之前对其进行压缩，因为这会影响打印质量。每个pdf的大小约为8MB，其中大部分由2张图片组成。图片为png格式，并在生成过程中转换为pdf（使用了第三方生成器）有没有一种方法可以在不使用第3方工具的情况下用Java压缩它们...
2024-01-10在JavaFX中显示pdf
开发JavaFX需要显示pdf 的桌面应用程序。我了解到JavaFX（当前版本）不支持pdf查看/显示，我也了解到JPedal。现在，问题：是否有任何外部组件或库可以在JavaFX中查看pdf？它应该是一个免费软件。 （如果必须使用JPedal）如何将其嵌入到我的应用程序中。回答：JPedalFX下载提供了有关使用JPedalFX的示例...
2024-01-10Java API，用于加密/解密pdf文件
我需要加密和解密pdf文件。有免费的或低成本的Java API可以做到吗？基本上，我需要向普通用户隐藏文件。关于以编程方式实现这一目标的任何其他建议？谢谢，深回答：使用iText： // Assuming you provide the following yourself: File inputFile; File outputFile; String userPassword; String ownerPassword; // A bit-field contai...
2024-01-10kafka 8和内存-Java运行时环境没有足够的内存来继续
我正在使用具有512兆内存ram的DigiOcean实例，使用kafka出现以下错误。我不是Java熟练的开发人员。如何调整卡夫卡以利用少量的ram。这是一个开发服务器。我不想为一台更大的机器每小时多付钱。## There is insufficient memory for the Java Runtime Environment to continue.# Native memory allocation (malloc) failed to allocate 986513408 ...
2024-01-10pdf能转换cad图纸吗
演示机型：华为MateBook X 系统版本：win10 APP版本：Adobe Illustrator CC 2020 1、能。方法如下：首先我们将AI软件打开，然后在菜单那里找到文件选项。 2、点击文件选项在其下拉列表里找到置入选项。 3、点击置入选项，在弹出的对话框内选择我们需要转换的PDF文件。 4、选择PDF文件之...
2024-01-10Java中的Docx至Pdf转换器
以下代码不适用于Apache poi 3.16。有人可以提供正确的解决方案吗，在我的项目中，有些人只能使用public void ConvertToPDF(String docPath, String pdfPath) { try { InputStream doc = new FileInputStream(new File(docPath)); XWPFDocument document = new XWPFDocument(doc); PdfOption...
2024-01-10
